#pragma once

#include "common/Pipeline.h"
#include "common/RouteUpdate.h"

#include <folly/MPMCPipeline.h>

namespace nexus {

class Normalizer {
 public:
  Normalizer(Pipeline& pipeline);
  // ~Normalizer() = default;

  void run();

 private:
  void process(RouteUpdate& dpu);

  Pipeline& pipeline_;
};
} // namespace nexus